package com.gjy.pulsar.disruptor;

import org.apache.pulsar.client.api.Message;

/**
 * @author gjy
 * @version 1.0
 * @since 2025-08-06 11:03:39
 */
public class PulsarMessageEvent {

    private Message<byte[]> pulsarMessage; // 原始Pulsar消息

    // Getter/Setter
    public Message<byte[]> getPulsarMessage() {
        return pulsarMessage;
    }
    public void setPulsarMessage(Message<byte[]> message) {
        this.pulsarMessage = message;
    }

}
